package com.threadpool.pool.queue;

import java.util.concurrent.TimeUnit;

/**
 * <p>
 * 任务队列接口
 * </p>
 *
 * @author 桌角的眼镜
 * @version 1.0
 * @since 2025/5/14 0:50
 */
public interface CustomBlockingQueue<T> {
    boolean offer(T task);

    T poll(long timeout, TimeUnit unit);

    T poll(); // <-- 新增这个非阻塞方法
}
